草庐IT

python - 在python线程中关闭监听套接字

全部标签

google-app-engine - 如何使用 Go 运行时在 App Engine 上的实例之间传递套接字?

Python运行时通过picklingtheconnection允许它.是否有类似的方式在经典AppEngine上使用Go运行时与google.golang.org/appengine/socket共享套接字? 最佳答案 描述符未在GoAPI中公开:https://github.com/golang/appengine/blob/master/socket/socket_classic.go#L152typeConnstruct{ctxcontext.Contextdescstringoffsetint64protpb.Create

Go logging struct 实例化实用方法的 Goroutine 线程安全

我正在使用一个新的go服务,我有一个SetupLogger实用函数,它创建一个新的go-kit日志结构实例log.Logger。从在单独的go-routines中处理请求的代码调用此方法是否安全?packageutilsimport("fmt""github.com/go-kit/kit/log""io""os""path/filepath")//Iftheenvironment-specifieddirectoryforwritinglogfilesexists,opentheexistinglogfile//ifitalreadyexistsorcreatealogfileifno

ruby - 这个示例 tcp 套接字编程事件顺序安全吗?

我计划提供两项服务。用Ruby编写的HTTPREST服务用Go编写的JSONRPC服务Ruby服务将打开一个到GoJSONRPC服务的TCP套接字连接。它将为收到的每个传入HTTP请求执行此操作。它会通过套接字向Go服务发送一些数据,然后该服务会通过套接字发回相应的数据。Go代码Go服务go看起来像这样(简化):srv:=new(service.App)//thiswouldexposeaProcessmethodrpc.Register(srv)listener,err:=net.Listen("tcp",":8080")iferr!=nil{//handleerror}for{co

go - 通过 SetDeadline() 为 TCP 监听器设置超时

我正在尝试实现非阻塞Accept(),目前为止最好的是以下代码片段(它是一个有效的Gov1.6.2程序):packagemainimport("net""log""time")funccreateClient(){tcpConn,err:=net.DialTCP("tcp4",nil,&net.TCPAddr{IP:net.IPv4(127,0,0,1),Port:12819,})iferr!=nil{log.Fatalln("Errorconnectingtotheserver!")}log.Println("Managedtodial!")tcpConn.Close()}funcm

networking - GoLang 监听端口范围

我正在尝试让一个程序在Go中的端口范围(520多个端口;TCP)上进行监听。不过,好像不行。它会听一些然后停止。我想做一个递增1的for循环,然后像这样调用一个监听函数:fori:=;i;i++{ipaddr:=fmt.Sprintf("8.8.8.8:%d",i)ipaddrnew,_:=parseAddress(ipaddr)golistener(ipaddrnew)}这就是我一直在尝试做的,但在尝试了几次之后就停止了。更新:这是我刚刚运行的测试:我将代码更改为以下内容:fori:=14480;i它给出了以下响应:1448014481144821448314484144851448

sockets - 检索确切的连接 - tcp 套接字 - channel - goroutine

我正在学习Golang几天,所以我不清楚如何在函数内检索正确的连接“conn”函数处理消息对于相关消息“msg”谢谢!packagemainimport("fmt""log""net""os""encoding/json""time""bufio")typePacketstruct{PayloadPayload`json:"payload"`}typePayloadstruct{Datastring`json:"data"`}funcmain(){iflen(os.Args)!=2{fmt.Fprintf(os.Stderr,"Usage:%shostname\n",os.Args[0

multithreading - Golang 线程池调度程序的目的和顺序

我刚刚用go写完了一个简单的代理应用程序:代码从一个接口(interface)获取UDP数据包,加密数据,然后使用TCP将其发送到另一个接口(interface)。目前,我正在使用三个goroutines:一个用于接收数据,一个用于加密,一个用于发送数据。我刚刚开始尝试寻找提高代码效率和速度的方法。首先,我想为每个需要加密的数据包创建一个新的goroutine,但在阅读了以下两篇博文后,我明白这不是正确的做法:http://marcio.io/2015/07/handling-1-million-requests-per-minute-with-golang/http://nesv.g

Go - Web 服务器在同一端口上监听多个协议(protocol)(HTTP 和 RTMP)

我正在尝试在Go中实现RTMP协议(protocol)以配合我的Web应用程序,但是我似乎无法找到在同一端口上同时处理HTTP和RTMP的解决方案。这个想法是这样的。packagemainimport("fmt""io""net/http")funcmain(){http.HandleFunc("/",func(whttp.ResponseWriter,r*http.Request){io.WriteString(w,"Hello!")})http.HandleFunc("/rtmp",func(whttp.ResponseWriter,r*http.Request){//RTMPha

http - 多线程Go for HTTP get

我在一个API中使用Go来获取我所在城市的公交车频率,但是当我尝试使HTTPGet访问许多URL时,我有点卡在了线程上。如果没有并发,程序需要超过16分钟才能完成1500个url调用以获取HTTP状态代码,我试图使用并发,但在阅读了很多帖子后我不明白goroutines是如何工作的......想法是制作一个函数并更改请求的数量,如下所示:gogetBusPostStatus(600,800)但我完全坚持...代码如下:packagemainimport("fmt""net/http""strconv""time")variint=0varconvStrstringvarmessage=

json - go 中的 ZeroMQ 不会打印我从 PULL 套接字接收到的 json 消息字节

我正在尝试一个简单的代码:packagemainimport("fmt"zmq"github.com/alecthomas/gozmq")funcmain(){context,_:=zmq.NewContext()defercontext.Close()//Sockettoreceivemessagesonreceiver,_:=context.NewSocket(zmq.PULL)deferreceiver.Close()receiver.Connect("tcp://localhost:5557")//Processtasksforeverfor{msgbytes,_:=recei